package com.asiainfo.dacp.datastash.worker.executor.adapter.datax.translate;

import java.io.Serializable;
import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.alibaba.fastjson.JSON;
import com.asiainfo.dacp.datastash.domain.unit.models.DataStashUnit;
import com.asiainfo.dacp.datastash.domain.unit.models.DataStashUnitStep;
import com.asiainfo.dacp.datastash.domain.unit.repos.DataStashUnitRepository;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.PluginCatalogType;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.PluginType;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.domain.Job;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.domain.JobId;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.domain.Step;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.domain.StepPair;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin.FtpReader;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin.FtpWriter;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin.HdfsReader;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin.HdfsWriter;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin.MysqlWriter;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin.RdbmsReader;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin.RdbmsWriter;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin.UnStructuredReader;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.model.plugin.UnStructuredWriter;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.utils.CommonErrorCode;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.utils.Configuration;
import com.asiainfo.dacp.datastash.worker.executor.adapter.datax.utils.WorkerException;
import com.asiainfo.dacp.metamodel.domain.ds.model.MetaDataSource;
import com.asiainfo.dacp.metamodel.domain.ds.repo.MetaDataSourceRepository;
import com.google.common.base.Preconditions;
import com.google.common.base.Splitter;
import com.google.common.base.Strings;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;

@Service
public class ParamTranslate extends JobTranslate {

	private static final Logger LOG = LoggerFactory.getLogger(ParamTranslate.class);
 

	@Override
	public Job translate(JobId id) {
		Job job = new Job(id); 

		return job;
	}
}
